-- **************************************************************************
--    Project Name:   集散错扫-汇总表
--    Job Name:       jms_dm__dm_report_site_errscan_detail_dt_sum
--    Description :   需要统计集散到件扫描时，实际扫描类型与应扫描类型不一致的件量
--    Author :        马诚
--    date：          2022/7/27
-- **************************************************************************
--    Relation ：
--    jms_dm__dm_report_site_errscan_detail_dt_sum  << [
--     jms_dm__dm_report_site_errscan_detail_dt
-- ]
--
--

-- **************************************************************************
--    modify by 马诚 2022/7/27 新增脚本

-- **************************************************************************
insert overwrite table jms_dm.dm_report_site_errscan_detail_dt_sum partition (dt)
--集散到件错扫汇总表
select 
     t.scan_time_ff as scan_time --扫描日期
    ,t.site_code  --网点编号
    ,t.site_name --网点名称
    ,t.proxy_area_code -- 代理区编号
    ,t.proxy_area_name -- 代理区名称
    ,t.franchisees_code -- 加盟商编号
    ,t.franchisees_name -- 加盟商名称
,sum(case when t.bill_type='in_bill' then 1 else 0 end ) as come_port_qty --进港件量
,sum(case when t.should_arrival_scantype <> t.real_arrival_scantype and t.should_arrival_scantype='到件扫描' then 1 else 0 end ) as err_collect_qty --错扫集货到件量

,sum(case when t.bill_type='out_bill' then 1 else 0 end ) as leave_port_qty  --出港件量
,sum(case when t.should_arrival_scantype <> t.real_arrival_scantype and t.should_arrival_scantype='集货到件' then 1 else 0 end ) as err_arrival_qty   --错扫卸车到件量
,t.dt
from jms_dm.dm_report_site_errscan_detail_dt t
where t.dt = '{{ execution_date | cst_ds }}'
group by 
     t.scan_time_ff --扫描日期
    ,t.site_code  --网点编号
    ,t.site_name --网点名称
    ,t.proxy_area_code -- 代理区编号
    ,t.proxy_area_name -- 代理区名称
    ,t.franchisees_code -- 加盟商编号
    ,t.franchisees_name -- 加盟商名称
    ,t.dt

 distribute by pmod(hash(rand()), 3);
